package com.siashan.unipay4j.wx.redpack;

import com.siashan.unipay4j.core.Result;
import com.siashan.unipay4j.core.UnipayConst;
import com.siashan.unipay4j.core.redpack.IRedpackQuery;
import com.siashan.unipay4j.core.redpack.RedpackQueryModel;
import com.siashan.unipay4j.core.redpack.RedpackQueryResponse;
import com.siashan.unipay4j.core.util.EnumUtil;
import com.siashan.unipay4j.core.util.MoneyUtil;
import com.siashan.unipay4j.wx.AbstractWxPay;
import com.siashan.unipay4j.wx.WxBizEnum;
import com.siashan.unipay4j.wx.sdk.WXPayConstants;
import lombok.extern.slf4j.Slf4j;

import java.util.HashMap;
import java.util.Map;

/**
 * 微信红包查询
 *
 * @author  siashan
 * @version  V1.0.1
 **/
@Slf4j
public class WxPayRedpackQuery extends AbstractWxPay implements IRedpackQuery {


    /**
     * 订单类型
     */
    private static final String BILL_TYPE = "MCHT";
    /**
     * 查询红包发放记录
     * 使用说明
     * 用于商户对已发放的红包进行查询红包的具体信息，可支持普通红包和裂变包。
     *
     * 注意事项
     * ◆ 查询红包记录API只支持查询30天内的红包订单，30天之前的红包订单请登录商户平台查询。
     * ◆ 如果查询单号对应的数据不存在，那么数据不存在的原因可能是：（1）发放请求还在处理中；（2）红包发放处理失败导致红包订单没有落地。在上述情况下，商户首先需要检查该商户订单号是否确实是自己发起的，如果商户确认是自己发起的，则请商户不要直接当做红包发放失败处理，请商户隔几分钟再尝试查询，或者商户可以通过相同的商户订单号再次发起发放请求。如果商户误把还在发放中的订单直接当发放失败处理，商户应当自行承担因此产生的所有损失和责任。
     * ◆ XML具有可扩展性，因此返回参数可能会有新增，而且顺序可能不完全遵循此文档规范，如果在解析回包的时候发生错误，请商户务必不要换单重试，请商户联系客服确认红包发放情况。如果有新回包字段，会更新到此API文档中。
     * ◆ 因为错误代码字段err_code的值后续可能会增加，所以商户如果遇到回包返回新的错误码，请商户务必不要换单重试，请商户联系客服确认红包发放情况。如果有新的错误码，会更新到此API文档中。
     * ◆ 错误代码描述字段err_code_des只供人工定位问题时做参考，系统实现时请不要依赖这个字段来做自动化处理。
     *
     * @param model   红包查询实体
     * @return        红包发放查询结果
     */
    @Override
    public Result<RedpackQueryResponse> execQuery(RedpackQueryModel model) {
        log.info("WxPayRedpackQuery => 订单{} 微信红包发放记录查询请求到达", model.getOutTradeNo());
        try {
            Map<String, String> r = initWxPay().sendRequest(wrapParam(model), WXPayConstants.MMPAYMKTTRANSFERS_GETHBINFO_URL_SUFFIX, WxBizEnum.REDPACK, true);
            log.info("WxPayRedpackQuery => 订单{} 微信红包发放记录查询请求返回报文:{}", model.getOutTradeNo(),r);
            String returnCode = r.get(WXPayConstants.RETURN_CODE);
            if (UnipayConst.SUCCESS.equals(returnCode)) {
                if (UnipayConst.SUCCESS.equals(r.get(WXPayConstants.RESULT_CODE))) {
                    log.info("WxPayRedpackQuery =>订单{} 微信红包发放记录查询返回成功", model.getOutTradeNo());
                    return Result.tradeSuccess(wrapResp(r));
                } else {
                    String errCode = r.get(WXPayConstants.ERR_CODE);
                    String errCodeDes = r.get(WXPayConstants.ERR_CODE_DES);
                    log.info("WxPayRedpackQuery =>订单{} 微信红包发放记录查询返回失败，错误代码:{},错误描述:{}", model.getOutTradeNo(),errCode,errCodeDes);
                    return Result.returnFail(errCode, errCodeDes);
                }
            } else {
                String returnMsg = r.get(WXPayConstants.RETURN_MSG);
                log.info("WxPayRedpackQuery =>订单{} 微信红包发放记录查询返回失败，错误代码:{},错误描述:{}", model.getOutTradeNo(),returnCode,returnMsg);
                return Result.returnFail(returnCode, returnMsg);
            }

        } catch (Exception e) {
            log.info("WxPayRedpackQuery =>订单{} 微信红包发放记录查询异常", model.getOutTradeNo(),e);
        }
        return Result.exception();
    }


    /**
     * 封装请求参数
     *
     * @param model    请求实体
     * @return         封装后的请求参数
     */
    private Map<String, String> wrapParam(RedpackQueryModel model) {
        Map<String, String> map = new HashMap<>();
        map.put("mch_billno", model.getOutTradeNo());
        map.put("bill_type", BILL_TYPE);

        return map;
    }


    /**
     * 封装红包记录查询返回结果
     *
     * @param r    微信返回报文
     * @return     返回结果
     */
    private RedpackQueryResponse wrapResp(Map<String, String> r){
        RedpackQueryResponse response = new RedpackQueryResponse();
        response.setState(EnumUtil.getIEnum(WxRedpackState.class,r.get("status")).getRedpackState());
        response.setAmount(MoneyUtil.cent2Yuan(Integer.parseInt(r.get("total_amount"))));
        response.setTotalNum(Integer.parseInt(r.get("total_num")));
        response.setOutTradeNo(r.get("mch_billno"));
        response.setTradeNo(r.get("detail_id"));
        response.setBody(r);
        return response;
    }
}
